a5c1ab78bf6fd0bba23bfd9d5072acd34b8b597d,opennms-snmp/opennms-snmp-api/src/main/java/org/opennms/netmgt/snmp/TableTracker.java,TableTracker,buildNextPdu,#PduBuilder#,98
Before Change
throw new IllegalArgumentException("maxVarsPerPdu < 1");
}
for (int i = 0; i < pduBuilder.getMaxVarsPerPdu(); i++) {
pduBuilder.addOid(m_lastOid[m_nextColumnIndex + i]);
}
pduBuilder.setNonRepeaters(0);
pduBuilder.setMaxRepetitions(getMaxRepetitions());
ResponseProcessor rp = new TableResponseProcessor(m_nextColumnIndex, pduBuilder.getMaxVarsPerPdu());
System.err.println("got response processor");
m_nextColumnIndex++;
After Change
}
@Override
public ResponseProcessor buildNextPdu(PduBuilder pduBuilder) {
if (pduBuilder.getMaxVarsPerPdu() < 1) {
throw new IllegalArgumentException("maxVarsPerPdu < 1");
}
Map<SnmpObjId, ResponseProcessor> processors = new HashMap<SnmpObjId,ResponseProcessor>(pduBuilder.getMaxVarsPerPdu());
for (ColumnTracker ct : getTrackers(pduBuilder.getMaxVarsPerPdu())) {
System.err.println("scheduling " + ct);
processors.put(ct.getBase(), ct.buildNextPdu(pduBuilder));
}
ResponseProcessor rp = new CombinedColumnResponseProcessor(processors);
System.err.println("got response processor");
return rp;
}